06820bf87c4983ac927ef62d0fbba634dae57575,quartz-core/src/test/java/org/quartz/AbstractJobStoreTest.java,AbstractJobStoreTest,testAcquireNextTriggerBatch,#,127
Before Change
assertEquals(trigger2.getKey(), acquiredTriggers.get(2).getKey());
assertEquals(trigger3.getKey(), acquiredTriggers.get(3).getKey());
this.fJobStore.releaseAcquiredTrigger(early);
this.fJobStore.releaseAcquiredTrigger(trigger1);
this.fJobStore.releaseAcquiredTrigger(trigger2);
this.fJobStore.releaseAcquiredTrigger(trigger3);
After Change
@SuppressWarnings("deprecation")
public void testAcquireNextTriggerBatch() throws Exception {
long baseFireTime = System.currentTimeMillis() - 1000;
OperableTrigger early =
new SimpleTriggerImpl("early", "triggerGroup1", this.fJobDetail.getName(),
this.fJobDetail.getGroup(), new Date(baseFireTime),
new Date(baseFireTime + 5), 2, 2000);
OperableTrigger trigger1 =
new SimpleTriggerImpl("trigger1", "triggerGroup1", this.fJobDetail.getName(),
this.fJobDetail.getGroup(), new Date(baseFireTime + 200000),
new Date(baseFireTime + 200005), 2, 2000);
OperableTrigger trigger2 =
new SimpleTriggerImpl("trigger2", "triggerGroup1", this.fJobDetail.getName(),
this.fJobDetail.getGroup(), new Date(baseFireTime + 210000),
new Date(baseFireTime + 210005), 2, 2000);
OperableTrigger trigger3 =
new SimpleTriggerImpl("trigger3", "triggerGroup1", this.fJobDetail.getName(),
this.fJobDetail.getGroup(), new Date(baseFireTime + 220000),
new Date(baseFireTime + 220005), 2, 2000);
OperableTrigger trigger4 =
new SimpleTriggerImpl("trigger4", "triggerGroup1", this.fJobDetail.getName(),
this.fJobDetail.getGroup(), new Date(baseFireTime + 230000),
new Date(baseFireTime + 230005), 2, 2000);
OperableTrigger trigger10 =
new SimpleTriggerImpl("trigger10", "triggerGroup2", this.fJobDetail.getName(),
this.fJobDetail.getGroup(), new Date(baseFireTime + 500000),
new Date(baseFireTime + 700000), 2, 2000);
early.computeFirstFireTime(null);
early.setMisfireInstruction(Trigger.MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY);
trigger1.computeFirstFireTime(null);
trigger2.computeFirstFireTime(null);
trigger3.computeFirstFireTime(null);
trigger4.computeFirstFireTime(null);
trigger10.computeFirstFireTime(null);
this.fJobStore.storeTrigger(early, false);
this.fJobStore.storeTrigger(trigger1, false);
this.fJobStore.storeTrigger(trigger2, false);
this.fJobStore.storeTrigger(trigger3, false);
this.fJobStore.storeTrigger(trigger4, false);
this.fJobStore.storeTrigger(trigger10, false);
long firstFireTime = new Date(trigger1.getNextFireTime().getTime()).getTime();
List<OperableTrigger> acquiredTriggers = this.fJobStore.acquireNextTriggers(firstFireTime + 10000, 4, 1000L);
assertEquals(1, acquiredTriggers.size());
assertEquals(early.getKey(), acquiredTriggers.get(0).getKey());
this.fJobStore.releaseAcquiredTrigger(early);
acquiredTriggers = this.fJobStore.acquireNextTriggers(firstFireTime + 10000, 4, 205000);
assertEquals(2, acquiredTriggers.size());
assertEquals(early.getKey(), acquiredTriggers.get(0).getKey());
assertEquals(trigger1.getKey(), acquiredTriggers.get(1).getKey());
this.fJobStore.releaseAcquiredTrigger(early);
this.fJobStore.releaseAcquiredTrigger(trigger1);
this.fJobStore.removeTrigger(early.getKey());
acquiredTriggers = this.fJobStore.acquireNextTriggers(firstFireTime + 10000, 5, 100000L);
assertEquals(4, acquiredTriggers.size());
assertEquals(trigger1.getKey(), acquiredTriggers.get(0).getKey());
assertEquals(trigger2.getKey(), acquiredTriggers.get(1).getKey());
assertEquals(trigger3.getKey(), acquiredTriggers.get(2).getKey());
assertEquals(trigger4.getKey(), acquiredTriggers.get(3).getKey());
this.fJobStore.releaseAcquiredTrigger(trigger1);
this.fJobStore.releaseAcquiredTrigger(trigger2);
this.fJobStore.releaseAcquiredTrigger(trigger3);
this.fJobStore.releaseAcquiredTrigger(trigger4);
acquiredTriggers = this.fJobStore.acquireNextTriggers(firstFireTime + 10000, 6, 100000L);
assertEquals(4, acquiredTriggers.size());
assertEquals(trigger1.getKey(), acquiredTriggers.get(0).getKey());
assertEquals(trigger2.getKey(), acquiredTriggers.get(1).getKey());